01957e8ab1fe83f2e7322cff5eebaf30607500cd,camel-core/src/main/java/org/apache/camel/processor/RedeliveryErrorHandler.java,RedeliveryErrorHandler,deliverToFailureProcessor,#Processor#boolean#Exchange#RedeliveryData#AsyncCallback#,777
Before Change
// store the last to endpoint as the failure endpoint
exchange.setProperty(Exchange.FAILURE_ENDPOINT, exchange.getProperty(Exchange.TO_ENDPOINT));
// and store the route id so we know in which route we failed
if (exchange.getUnitOfWork().getRouteContext() != null) {
exchange.setProperty(Exchange.FAILURE_ROUTE_ID, exchange.getUnitOfWork().getRouteContext().getRoute().getId());
}
// the failure processor could also be asynchronous
After Change
// store the last to endpoint as the failure endpoint
exchange.setProperty(Exchange.FAILURE_ENDPOINT, exchange.getProperty(Exchange.TO_ENDPOINT));
// and store the route id so we know in which route we failed
UnitOfWork uow = exchange.getUnitOfWork();
if (uow != null && uow.getRouteContext() != null) {
exchange.setProperty(Exchange.FAILURE_ROUTE_ID, uow.getRouteContext().getRoute().getId());
}